Наименование компонента: модуль вычисления дайджестов.
Модуль предназначен для расчёта состояний файла, гарантирующего отсутствие изменений.
Основные функции модуля:
- прослушивание топика kafka (digest.file.uploaded);
- при получении сообщения скачивает файл с хранилища данных VK S3 по ссылке в сообщении;
- вычисление состояния, упаковка его в сообщение и отправка результата в исходящий топик (digest.completed);
- контроль ошибок (с использованием топика digest.error).
Добавить комментарий